/* ***** BEGIN LICENSE BLOCK *****
 * Version: MPL 1.1/GPL 2.0/LGPL 2.1
 *
 * The contents of this file are subject to the Mozilla Public License Version
 * 1.1 (the "License"); you may not use this file except in compliance with
 * the License. You may obtain a copy of the License at
 * http://www.mozilla.org/MPL/
 *
 * Software distributed under the License is distributed on an "AS IS" basis,
 * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
 * for the specific language governing rights and limitations under the
 * License.
 *
 * The Original Code is COID mud service.
 *
 * The Initial Developer of the Original Code is
 * PosAm.
 * Portions created by the Initial Developer are Copyright (C) 2003
 * the Initial Developer. All Rights Reserved.
 *
 * Contributor(s):
 * Brano Kemen
 *
 * Alternatively, the contents of this file may be used under the terms of
 * either the GNU General Public License Version 2 or later (the "GPL"), or
 * the GNU Lesser General Public License Version 2.1 or later (the "LGPL"),
 * in which case the provisions of the GPL or the LGPL are applicable instead
 * of those above. If you wish to allow use of your version of this file only
 * under the terms of either the GPL or the LGPL, and not to allow others to
 * use your version of this file under the terms of the MPL, indicate your
 * decision by deleting the provisions above and replace them with the notice
 * and other provisions required by the GPL or the LGPL. If you do not delete
 * the provisions above, a recipient may use your version of this file under
 * the terms of any one of the MPL, the GPL or the LGPL.
 *
 * ***** END LICENSE BLOCK ***** */
 
 
#include "coid/comm/dynarray.h"
#include "coid/comm/keywordt.h"

#include "coid/svc/coidsvc.h"
#include "../mudport/client/mudport_client.h"

#include "../colors.h"

////////////////////////////////////////////////////////////////////////////////
struct StenchMud
{
    cmd_interface* _cmdin;
    dynarray<uint> _clients_new;

    typedef MudPort_client              Port;
    typedef keywordmap<uint,Port*>      Clmap;

    Clmap _clients_connected;


    opcd init() { return 0; }

    opcd run()
    {
        sysMilliSecondSleep(1000);

        dynarray<charstr>  secdlog;
        while( !_cmdin->is_exit_signalled() )
        {
            {
                // lock for access
                CMDIN_GUARD(_cmdin);
                dynarray<charstr>  logturn;

                // process new connects
                for( uint i=0; i<_clients_new.size(); ++i )
                {
                    local<Port> port = new Port;
                    opcd e = port->connect_shared( _clients_new[i], "localhost:55099" );
                    if(!e)
                    {
                        _clients_connected.insert( _clients_new[i], port.eject() );
                        charstr& t = *logturn.add(1);

                        t << "connected new client";
                    }
                }
                _clients_new.reset();

                secdlog.append(logturn);
                logturn.reset();

                // upd output for connected clients
                //if( logturn.size() > 0 )
                {
                    dynarray<charstr>  msgturn;
                    msgturn.takeover(secdlog);

                    Clmap::const_iterator cb = _clients_connected.begin();
                    Clmap::const_iterator ce = _clients_connected.end();
                    for( ; cb!=ce; ++cb )
                    {
                        Port* p = (*cb).second;
                        dynarray<charstr> inbuf;
                        void* pcr;
                        p->fetch( inbuf, &pcr );
                        p->flush( msgturn );
                        secdlog.append(inbuf);
                    }
                }
            }

            sysMilliSecondSleep(10);
        }
        return 0;
    }
};